package com.iot.service.mqtt.bridge.db;

import com.iot.service.mqtt.bridge.AbstractBridgeObserver;
import com.iot.service.mqtt.bridge.TlSubject;
import com.iot.service.mqtt.model.request.TlMqttPublishReq;
import lombok.extern.slf4j.Slf4j;

/**
 * @Author: hszhou
 * @Date: 2025/2/27 16:30
 * @Description: 数据库桥接数据
 */
@Slf4j
public class MySqlBridgeObserver extends AbstractBridgeObserver {

    protected TlSubject subject;


    public MySqlBridgeObserver(TlSubject subject) {
        this.subject = subject;
        this.subject.attach(this);
    }
    @Override
    protected void forward(String clientId, int qos, TlMqttPublishReq req) {

        //todo 这里需要判断是否配置了数据库桥接

    }
}
